﻿using Nest;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Elasticsearch.Synchronize.Job.Tailer
{
    public class BaseTailer
    {
        protected readonly ElasticClient _elasticClient;

        protected BaseTailer(string url)
        {
            var settings = new ConnectionSettings(new Uri(url));
            settings.DisableDirectStreaming();
            settings.DefaultFieldNameInferrer(f => f);
            _elasticClient = new ElasticClient(settings);
        }
    }
}
